package com.theaf.core.mq.message;

import lombok.Data;

import java.io.Serializable;

/**
 * 消费封装类
 *
 * @author luojuan
 * @create 2017-11-28 9:49
 **/
@Data
public class Message implements Serializable{
    private static final long serialVersionUID = 1L;
    /**
     * 消息标签(系统标识), 请使用合法标识符, 尽量简短且见名知意
     */
    private String tag;
    /**
     * 消息主题, 最长不超过255个字符; 由a-z, A-Z, 0-9, 以及中划线"-"和下划线"_"构成.
     */
    private String topic;
    /**
     * 延迟投递时间单位秒(s)
     */
    private Integer delayTime;
    /**
     *  消息体, 消息体长度默认不超过4M, 具体请参阅集群部署文档描述.
     */
    private MessageBody body;

    public Message(String topic , String tag , MessageBody body){
        this.topic = topic ;
        this.tag = tag ;
        this.body = body ;
    }

    public Message(){
        this.body = new MessageBody();
    }
}
